5e0cdd4456a8c6a252d706bdc7cb89038df09959,runtime/src/test/java/io/rx_cache/internal/ProvidersDynamicsKeysRxCacheTest.java,ProvidersDynamicsKeysRxCacheTest,Pagination,#,53

Before Change


    List<Mock> mocksPage3 = createMocks(SIZE);
    String mockPage3Value = mocksPage3.get(0).getMessage();

    subscriber = new TestSubscriber<>();
    providersRxCache.getMocksPaginate(Observable.just(mocksPage3), new DynamicKey(3))
        .subscribe(subscriber);
    subscriber.awaitTerminalEvent();

    subscriber = new TestSubscriber<>();
    providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(1))
        .subscribe(subscriber);
    subscriber.awaitTerminalEvent();
    assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage1Value));

    subscriber = new TestSubscriber<>();
    providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(2))
        .subscribe(subscriber);
    subscriber.awaitTerminalEvent();
    assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage2Value));

    subscriber = new TestSubscriber<>();
    providersRxCache.getMocksPaginate(Observable.<List<Mock>>just(null), new DynamicKey(3))
        .subscribe(subscriber);
    subscriber.awaitTerminalEvent();
    assertThat(subscriber.getOnNextEvents().get(0).get(0).getMessage(), is(mockPage3Value));
  }

After Change


    List<Mock> mocksPage3 = createMocks(SIZE);
    String mockPage3Value = mocksPage3.get(0).getMessage();

    testObserver =
        providersRxCache.getMocksPaginate(Observable.just(mocksPage3), new DynamicKey(3)).test();
    testObserver.awaitTerminalEvent();

    testObserver =
        providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(1))
            .test();
    testObserver.awaitTerminalEvent();
    assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage1Value));

    testObserver =
        providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(2))
            .test();
    testObserver.awaitTerminalEvent();
    assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage2Value));

    testObserver =
        providersRxCache.getMocksPaginate(ClearProvider.<List<Mock>>now(), new DynamicKey(3))
            .test();
    testObserver.awaitTerminalEvent();
    assertThat(testObserver.values().get(0).get(0).getMessage(), is(mockPage3Value));
  }